//package lzzsrj.union.message.config;
//
//import lzzsrj.union.message.constant.MessageConstants;
//import lzzsrj.union.message.producer.ProducerRedisImpl;
//import org.redisson.api.RKeys;
//import org.redisson.api.RedissonClient;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.context.annotation.Configuration;
//
//import javax.annotation.PostConstruct;
//
//@Configuration
//public class RedisMessageConfig {
//
//    @Autowired
//    private RedissonClient redissonClient;
//
//    @Autowired
//    private ProducerRedisImpl producerRedisImpl;
//
//    /**
//     * 将存在redis中的消息抓取出来进行监听
//     */
//    @PostConstruct
//    public void initExistRedisMessage() {
//        if (redissonClient != null && !redissonClient.isShutdown()) {
//            RKeys keys = redissonClient.getKeys();
//            Iterable<String> matchingKeys = keys.getKeysByPattern(MessageConstants.RedisMessage.PREFIX_REDIS_MESSAGE + "*");
//            for (String key : matchingKeys) {
//                System.out.println(key);
//                producerRedisImpl.getRedissonDelayQueue(key);
//            }
//        }
//
//
//
//    }
//}
